package com.yuw.threaddemo;

public class ProducerThread extends Thread {
    // 属性
    // 仓库属性
    private MyStack myStack;

    // 行为

    public ProducerThread(MyStack myStack) {
        this.myStack = myStack;
    }

    @Override
    public void run() {
        // 业务逻辑处理
        for (; ; ) {
            // 生产者生产一个产品
            Goods goods = new Goods("商品X", 10.5);
            // 生产者将产品入库
            myStack.push(goods);
            // 线程休眠1000ms
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
